// SSE中间件
export default async (ctx, next) => {
//   if (ctx.path === '/api/sse') {
//     console.log('SSE中间件处理请求:', ctx.path, ctx.method)
    
//     // 设置SSE响应头
//     ctx.set({
//       'Content-Type': 'text/event-stream',
//       'Cache-Control': 'no-cache',
//       'Connection': 'keep-alive',
//       'Access-Control-Allow-Origin': '*',
//       'Access-Control-Allow-Headers': 'Cache-Control',
//       'Access-Control-Allow-Credentials': 'true'
//     })
  
//     // 设置状态码为200
//     ctx.status = 200
//     ctx.respond = false
  
//     // 发送初始连接确认
//     ctx.res.write('data: SSE连接已建立\n\n')
  
//     let counter = 0
//     const timer = setInterval(() => {
//       counter++
//       const message = `data: Message ${counter}\n\n`
//       ctx.res.write(message)
      
//       if (counter >= 10) {
//         clearInterval(timer)
//         ctx.res.write('data: [DONE]\n\n')
//         ctx.res.end()
//       }
//     }, 1000)
  
//     // 处理客户端断开连接
//     ctx.req.on('close', () => {
//       console.log('SSE客户端断开连接')
//       clearInterval(timer)
//     })
    
//     // 处理客户端错误
//     ctx.req.on('error', (err) => {
//       console.log('SSE连接错误:', err)
//       clearInterval(timer)
//     })
    
//     return // 不继续执行后续中间件
//   }
  
//   await next()
}
